package com.myFwk.service.serviceImpl;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Service;

/**
 * @Title: 当消息发送到Exchange的时候此方法会被被触发，确认消息到达exchange
 * @Description:
 * @Author: guowl
 * @version： 1.0
 * @Date:2021/10/25
 * @Copyright: Copyright(c)2021 RedaFlight.com All Rights Reserved
 */
@Service
@Slf4j
public class ConfirmCallbackService implements RabbitTemplate.ConfirmCallback {


    @Override
    public void confirm(CorrelationData correlationData, boolean b, String s) {
        log.info("ConfirmCallback ID:{},内容:{}", correlationData, b, s);
    }
}
